package cn.z2huo.demo.hello.kafka.model;

import org.apache.kafka.clients.producer.ProducerRecord;

import java.io.Serial;
import java.io.Serializable;
import java.util.Map;

/**
 * <p>
 *
 * @author z2huo
 */
public class KafkaRequest<K,V> implements Serializable {

    @Serial
    private static final long serialVersionUID = -2403659504767098162L;

    private ProducerRecord<K,V> record;

    /**
     * 调用方唯一标识
     */
    private String callerId;

    /**
     * 接口标识方法 ID，通过此找 kafkaRegisterInfo
     */
    private String providerId;

    private String pkId;

    private Object[] argsData;

    private Map<String, String> trackData;

    private Boolean persistent;

    private String messageKey;

    private String messageId;

}
